package ex.datastream.functions.richFunction;

import ex.vo.Item;
import org.apache.flink.api.common.functions.RichMapFunction;

public class RichMapFuncMyMap extends RichMapFunction<Item,String> {

    @Override
    public String map(Item item) throws Exception {
        return item.getName()+"MyMapFunction";
    }


}